package com.zjc.mymq.client.consumer;


import java.util.List;

/**
 * @author zjc
 * @date Created in 11:05 2024/7/16
 *  数据消费监听器
 */
public interface MessageConsumeListener {


    /**
     * 默认的消费处理函数
     *
     * @param consumeMessages
     * @return
     */
    ConsumeResult consume(List<ConsumeMessage> consumeMessages) throws InterruptedException;
}
